package com.fanshuai.spring.boot.component.listener;

import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.core.Ordered;

public interface ConsumerListener extends Ordered {
    void beforeConsume(ConsumerRecord<String, String> record);
    void afterConsume(ConsumerRecord<String, String> record);
}
